package com.example.rabbitmq.comsumer.topic;/**
 * ClassName: TopicReceiverB <br/> Description: <br/> date: 2022/1/24 11:07<br/>
 *
 * @author chenzhian<br />
 * @version
 */

import com.example.common.config.RabbitMQConfig;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @Author: chenzhian
 * @Date: 2022/1/24 11:07
 * @Description:
 */
@Component
@RabbitListener(queues = {RabbitMQConfig.RABBITMQ_TOPIC_QUEUE_B})
public class TopicReceiverB {

  @RabbitHandler
  public void process(String msg) {
    System.out.println("Topic ReceiverB: " + msg);
  }
}